//package com.ask.mq.consumer;
//
//import com.ask.entity.LikeMessage;
//import com.ask.service.businessService.IBlogService;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.messaging.handler.annotation.Payload;
//import org.springframework.stereotype.Service;
//
//@Service
//@Slf4j
//public class LikeMessageConsumer {
//    @Autowired
//    private IBlogService blogService;
//
//    /**
//     * 消费者，处理博客点赞
//     *
//     * @param message
//     */
//    @KafkaListener(topics = "like-topic", groupId = "likeBlog-consumer-group")
//    public void handleLikeMessage(@Payload LikeMessage message) {
//        Long blogId = message.getBlogId();
//        Long userId = message.getUserId();
//        // 点赞
//        if (message.getAction() == LikeMessage.Action.LIKE) {
//            boolean success = blogService.update()
//                    .setSql("liked = liked + 1")
//                    .eq("id", blogId)
//                    .update();
//            if (success) {
//                log.info("用户{}成功对博客{}点赞，数据库已跟新", userId, blogId);
//            } else {
//                log.info("用户{}对博客{}点赞，数据库跟新失败", userId, blogId);
//            }
//        }
//        // 取消点赞
//        else {
//            boolean success = blogService.update()
//                    .setSql("liked = liked - 1")
//                    .eq("id", blogId)
//                    .update();
//            if (success) {
//                log.info("用户{}成功对博客{}取消点赞，数据库已更新", userId, blogId);
//            } else {
//                log.info("用户{}对博客{}取消点赞，数据库跟新失败", userId, blogId);
//            }
//        }
//    }
//}
